package com.example.kafkasp.Service;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.transaction.annotation.Transactional;

/**
 * @author CHENTAIWEN
 * @create 2022/8/24 15:07
 */
public interface EsChannel {

    String STREAM_DEMO1_OUTPUT ="demo_1_output";
    String STREAM_DEMO2_OUTPUT ="demo_2_output";

    @Output(STREAM_DEMO1_OUTPUT)
    MessageChannel messageDemo1Output();

    @Output(STREAM_DEMO2_OUTPUT)
    MessageChannel messageDemo2Output();
}